package com.lichao.FinkDataProcess.codehaus;

import com.lichao.FinkDataProcess.pojo.Rules;
import org.apache.flink.util.OutputTag;

import java.util.List;
import java.util.Map;

public class SideOutputTag {

    private static void topicSideOutputTagMap(List<Rules> rules,Map<String, OutputTag<String>> map){


        for (Rules rule : rules) {
            if (rule.getTopic() != null) {
                StringBuilder sb = new StringBuilder(rule.getTopic());

                OutputTag<String> sideOutputTag = new OutputTag<String>(rule.getTopic() + "_side-output") {
                };
                map.put(rule.getTopic(), sideOutputTag);
            }
        }
    }
}


